package com.niren.relay.common.queues;

import java.util.LinkedList;
import java.util.Queue;

public class AtomQueue<T> {
	Queue<T> queue = new LinkedList<T>();
	
	public int GetQueueCount() {
		return queue.size();
	}
	
	/**
	 * 加锁是为了具有原子性
	 * */
	public synchronized void InQueue(T t) {
		queue.offer(t);
	}//alt+/ 是提示 你试试
	
	/**
	 * 加锁是为了具有原子性
	 * */
	public synchronized T OutQueue() {
		return queue.poll();
	}
}
